<?php
/**
 * Created by PhpStorm.
 * User: WenQing
 * Date: 2017/7/21
 * Time: 16:53
 */
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

/**
 * 使用lpush + brpop实现简单的redis队列
 */

//生产者
$user = [
    'id' => 1,
    'name' => 'test',
    'todo' => 'work'
];
$redis->lPush('queue',json_encode($user));

//消费者
$info = $redis->brPop(['queue'],10); //获取要处理的队列数据 处理失败了可以再次将数据放入队列中，重复处理数据
